/**
 * 
 */
package com.qolome.order.message;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @Description: 客户端 
 * @author 姜锋
 * @date 2020年1月21日 下午6:50:49 
 * @version V1.0   
 *
 */
public interface StreamClient {
	String INPUT = "myMessageInput";
	String OUTPUT ="myMessageOut";
	
	@Input(StreamClient.INPUT)
	SubscribableChannel input();
	
	@Output(StreamClient.OUTPUT)
	MessageChannel output();
}
